package com.gree.grih.datastream;

import org.apache.log4j.Logger;
import org.apache.storm.topology.BasicOutputCollector;
import org.apache.storm.topology.OutputFieldsDeclarer;
import org.apache.storm.topology.base.BaseBasicBolt;
import org.apache.storm.tuple.Tuple;

/**
 * HbaseBolt
 * Created by wander on 21th.Apr.2017
 */
public class HbaseBolt extends BaseBasicBolt {

    private static Logger logger = Logger.getLogger(BaseBasicBolt.class);

    public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {
        logger.info(tuple.toString());
    }

    public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {

    }
}
